package cn.com.cmbc.utils;

import cn.com.cmbc.dao.KafkaDAO;
import com.google.gson.Gson;
import com.google.gson.JsonObject;

public class JSONUtil {
    private static final Gson gson = new Gson();
    public static String getMessage(String json) {
        // 将JSON字符串转换为JsonObject
        JsonObject jsonObject = gson.fromJson(json, JsonObject.class);

        // 获取message字段的值
        String message = jsonObject.get("message").toString();

        // 将JSON字符串转换为JSONObject
//        JSONObject jsonObject = JSON.parseObject(json);
//
//        // 获取message字段的值
//        String message = jsonObject.getString("message");

        // 打印message字段的值
        System.out.println("Message: " + message);

        return message;
    }

    public static String POJOtoJson(KafkaDAO kafkaDAO){
        return gson.toJson(kafkaDAO, KafkaDAO.class);
    }
}
